package com.pk.flink.functions.source;

import com.pk.flink.bean.Access;
import org.apache.flink.streaming.api.functions.ProcessFunction;
import org.apache.flink.util.Collector;

public class AccessSideOutputFunction extends ProcessFunction<Access, Access> {

    @Override
    public void processElement(Access access, Context context, Collector<Access> collector) throws Exception {

    }
}
